package gspushmq.v1.main;

import gspushmq.v1.subscribe.handler.core.GGHandlerPush;
import gspushmq.v1.subscribe.send.GGSendApi;
import gspushmq.v1.subscribe.send.GGSendSys;
import gspushmq.v1.subscribe.send.GGSendSysTags;
import gspushmq.v1.thread.GGThreadPool;


/**
 * 服务端推送消息给客户端
 *
 * @author yutao
 * @version 1.0
 * @company 上海朝阳永续信息技术有限公司
 * @copyright (c) 2016 SunTime Co'Ltd Inc.All rights reserved.
 * @date 2018年11月6日下午2:42:59
 * @since JDK1.7
 */
public class GGHandlerAndSendMQ {

	public static void start() {
		//逻辑处理
		GGThreadPool.threadPool.execute(new GGHandlerPush());
		//推送
		GGThreadPool.threadPool.start(new GGSendApi());
		GGThreadPool.threadPool.start(new GGSendSysTags());
	}
}
